package com.leezai.mqtt.handler;



/**
 * MQTT消息处理器接口
 * 第三方使用者可以实现此接口来自定义消息处理逻辑
 */
public interface MessageProcessor {

    /**
     * 自定义消息处理逻辑
     * @param topic 消息主题
     * @param originalPayload 原始字节数据
     */
    void handleMessage(String topic, byte[] originalPayload);

}
